//引入express
var express=require('express')
//引入连接池模块
var pool=require('../pool')
//创建路由对象
const router=express.Router()

//下面为所有的路由
//用户注册的接口（post /reg）
router.post('/reg',(req,res,next)=>{
  var obj=req.body
  console.log(obj)
  pool.query('insert into user set ?',[obj],(err,data)=>{
    if(err){
      next(err);
      return;
    }
    console.log(data)
    if(data.affectedRows==0){
      res.send({code:0,msg:"注册失败"})}
      else{
        res.send({code:1,msg:'注册成功'})
     }
  })
})


//用户修改个人信息2.0 post /edit
router.put('/edit',(req,res,next)=>{
  var obj=req.body
  console.log(obj)
  //sql语句验证
  let sql=
  `update user set user-name='${obj.unames}',user-phone='${obj.uphone}',user-email=${obj.email} where u-phone='${obj.oldphone}';`
  
  console.log(sql)
  pool.query(sql,
    (err,result)=>{
      if(err){
        next(err);
        return
      }
      console.log(result)
      if(result.affectedRows==0){
        res.send({code:0,msg:"修改失败"})
      }else{
        res.send({code:1,msg:"修改成功"})
      }
  })
})

//1.1用户登录接口
//（post  /login）
router.post('/login',(req,res,next)=>{
  //console.log('有访问了')
  let obj=req.body
  console.log(obj)
  //执行sql到数据库查询数据
 pool.query('select * from user where user-name=? && user-password=?;',
             [obj.unames,obj.upwd],
             (err,data)=>{
                   if(err){
                        next(err);
                        return
  }
  //console.log(data)
  if(data.length==0){
    res.send({code:0,msg:'登录失败'})
  }else{
    res.send({code:1,msg:'登录成功'})
  }
 })
})

//暴露路由对象
module.exports=router